# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dwd.tab.dwd_tab_barscan_send_base_dt import jms_dwd__dwd_tab_barscan_send_base_dt
from jms.dwd.tab.dwd_tab_barscan_bagging_base_dt import jms_dwd__dwd_tab_barscan_bagging_base_dt

export_in_center_entrepot_package_waynum_oss = BashOperator(
    task_id='export_in_center_entrepot_package_waynum_oss',
    email=['shenjiaming@jtexpress.com', 'yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/export_in_center_entrepot_package_waynum_oss/execute.sh',
    execution_timeout=timedelta(minutes=50),
)

export_in_center_entrepot_package_waynum_oss << [
    jms_dwd__dwd_tab_barscan_send_base_dt
    , jms_dwd__dwd_tab_barscan_bagging_base_dt
]
